package io.dy.mq;

import java.io.Serializable;

/**
 * @author dmj
 * @date 2024年03月25日 下午1:46
 * 消息载体
 */
public final class Message<K,T> implements Serializable {
    /**
     * 唯一标识
     */
    private final K key;

    /**
     * 消息体
     */
    private final T body;

    public K getKey() {
        return key;
    }

    public T getBody() {
        return body;
    }

    public Message(K key, T body) {
        this.key = key;
        this.body = body;
    }

    @Override
    public String toString() {
        return "Message{" +
                "key=" + key +
                ", body=" + body +
                '}';
    }
}
